// 自定义Promise函数模块：IIFE(ES5定义模块匿名函数表达式自用)

(function (window) {

    const PENDING = 'pending'
    const RESOLVED = 'resolved'
    const REJECTED = 'rejected'

    /** Promise类版本
    *   参数 executor :执行器函数(同步执行)
    */
    class Promise {
        constructor(executor) {
            // 将当前promise对象保存起来
            const self = this

            // 给promise对象指定status属性，初始值为pending
            self.status = PENDING

            // 给promise对象指定一个用于 存储结果数据 的属性
            self.data = undefined

            // 每个元素结构：{onResolved(){} , onRejected(){}}
            self.callbacks = []

            function resolve(value) {
                // 如果当前状态不是pending，直接结束
                if (self.status !== PENDING) {
                    return
                }

                // 将状态改为resolved
                self.status = RESOLVED

                // 保存value数据
                self.data = value

                // 如果有待执行 callback函数 ，立即异步执行回调函数onResolved
                if (self.callbacks.length > 0) {
                    setTimeout(() => {
                        // 放入队列中执行所有成功的回调
                        self.callbacks.forEach(callbacksObj => {
                            callbacksObj.onResolved(value)
                        })
                    });
                }
            }

            function reject(reason) {
                // 如果当前状态不是pending，直接结束
                if (self.status !== PENDING) {
                    return
                }

                // 将状态改为rejected
                self.status = REJECTED

                // 保存value数据
                self.data = reason

                // 如果有待执行 callback函数 ，立即异步执行回调函数onRejected
                if (self.callbacks.length > 0) {
                    setTimeout(() => {
                        // 放入队列中执行所有成功的回调
                        self.callbacks.forEach(callbacksObj => {
                            callbacksObj.onRejected(reason)
                        })
                    });
                }
            }

            // 立即同步执行executor
            try {
                executor(resolve, reject)
            } catch (err) {
                // 如果执行器抛出异常，promise对象变为rejected状态
                reject(error)
            }
        }

        /** Promise原型对象的 then()
         *  描述 : 指定成功和失败的回调函数
         *         返回一个新的promise对象
         *         返回promise的结果由onResolved/onRejected执行的结果决定
         */
        then(onResolved, onRejected) {

            // 将当前promise对象保存起来
            const self = this

            // 指定默认的成功的回调(实现错误/异常穿透的关键点)
            onResolved = typeof onResolved === 'function' ? onResolved : value => value
            // 指定默认的失败的回调(实现错误/异常穿透的关键点)
            onRejected = typeof onRejected === 'function' ? onRejected : reason => { throw reason }

            //  返回一个新的promise对象
            return new Promise((resolve, reject) => {

                // 调用指定的回调函数处理，根据执行结果，改变return的Promise的状态
                function handle(callback) {
                    try {
                        const result = callback(self.data)
                        if (result instanceof Promise) {
                            // 3.如果回调函数返回的是promise，return的promise结果就是这个promise的结果
                            result.then(
                                value => resolve(value),
                                reason => reject(reason)
                            )
                            // 另外一种写法
                            // result.then(resolve,reject)
                        } else {
                            // 2.如果回调函数返回的不是promise，return的promise就会成功，value就是返回的值
                            resolve(result)
                        }
                    } catch (error) {
                        // 1.如果抛出异常，return的promise就会失败，reason就是error
                        reject(error)
                    }
                }

                // 判断status的状态，做不同的操作
                if (self.status === PENDING) {
                    // 'pending'状态，先将回调函数保存起来
                    self.callbacks.push({
                        onResolved(value) {
                            handle(onResolved)
                        },
                        onRejected(reason) {
                            handle(onRejected)
                        }
                    })
                } else if (self.status === RESOLVED) {
                    // 'resolved',异步执行onResolved并改变return的promise状态
                    setTimeout(() => {
                        handle(onResolved)
                    });
                } else {
                    // 'rejected'，异步执行 onRejected 并改变return的promise状态
                    setTimeout(() => {
                        handle(onRejected)
                    });
                }
            })


        }

        /** Promise原型对象的 catch()
         *  描述：指定失败的回调函数，返回一个新的promise对象
         */
        catch(onRejected) {
            return this.then(undefined, onRejected)
        }

        /** Promise函数对象的 resolve 方法
         *  描述：返回 指定结果 的一个成功的promise
         *  */
        static resolve(value) {
            // 返回一个成功/失败的promise
            return new Promise((resolve, reject) => {
                if (value instanceof Promise) {
                    // value是一个promise，使用value的结果作为promise的结果
                    value.then(resolve, reject)
                } else {
                    // value不是promise => promise变为成功，数据是value
                    resolve(value)
                }
            })
        }

        /** Promise函数对象的 reject 方法
         *  描述：返回 指定reason 的失败的promise
         *  */
        static reject(reason) {
            // 返回一个失败的promise
            return new Promise((resolve, reject) => {
                reject(reason)
            })
        }

        /** Promise函数对象的 all 方法
         *  描述：返回一个promise，只有当所有的promise都成功时才成功，否则失败
         *  */
        static all(promises) {

            // 用来保存所有成功value的数组
            const values = new Array(promises.length)

            // 用来保存成功promise的数量
            let resolvedCount = 0

            // 返回一个新的promise
            return new Promise((resolve, reject) => {
                // 遍历promises获取每个promise的结果
                promises.forEach((p, index) => {
                    Promise.resolve(p).then(
                        value => {
                            // 成功的数量加1
                            resolvedCount++

                            // p成功，将成功的value保存values
                            values[index] = value

                            // 如果全部成功，将return的promise改为成功
                            if (resolvedCount === promises.length) {
                                resolve(values)
                            }
                        },
                        reason => {
                            // 只要有一个失败了，return的promise就失败
                            reject(reason)
                        }
                    )
                })

            })
        }

        /** Promise函数对象的 race 方法
         *  描述：返回一个promise，其结果由第一个完成的promise决定
         *  */
        static race(promises) {
            return new Promise((resolve, reject) => {
                promises.forEach(p => {
                    Promise.resolve(p).then(
                        value => {
                            resolve(value)
                        },
                        reason => {
                            reject(reason)
                        }
                    )
                })
            })
        }

        /** 自定义 Promise函数对象的 resolveDelay 方法
         *  描述：返回一个promise对象，它在指定的时间后才确定结果
         */
        static resolveDelay(value, time) {
            // 返回一个成功/失败的promise
            return new Promise((resolve, reject) => {
                setTimeout(() => {
                    if (value instanceof Promise) {
                        // value是一个promise，使用value的结果作为promise的结果
                        value.then(resolve, reject)
                    } else {
                        // value不是promise => promise变为成功，数据是value
                        resolve(value)
                    }
                }, time);
            })
        }

        /** 自定义 Promise函数对象的 rejectDelay 方法
         *  描述：返回一个promise对象，它在指定的时间后才失败
         */
        static rejectDelay(reason, time) {
            // 返回一个成功/失败的promise
            return new Promise((resolve, reject) => {
                setTimeout(() => {
                    reject(reason)
                }, time);
            })
        }
    }





    // 向外暴露Promise函数
    window.Promise = Promise
})(window)

